package com.kafka.service.carMsg.impl;

import com.kafka.service.carMsg.MsgObserver;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * @descriptions:
 * @author: yunqiang
 * @date: 2022/1/5 16:03
 */
@Component
@Slf4j
public class TestMsg implements MsgObserver {
    @Override
    public void send(String message) {
        log.info("后台处理消息："+message);
    }
}
